package cn.tpshion.pulsar.annoation;

import java.lang.annotation.*;

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface PulsarConsumer {

    String topic();

    String consumerName();

    boolean autoAck() default true;

}
